package com.tl.job014.manager;

import org.apache.kafka.clients.producer.ProducerRecord;

import com.tl.job014.utils.kafka.KafkaProducerUtil4Java;

/**
 * 负责将接收到的数据，转发到Kafka集群即可
 * 
 * @author yingfing
 * @date 2021年3月3日 @time 下午2:57:31
 */
public class DataSendManager4Kafka {

	private static KafkaProducerUtil4Java producerUtil = null;
	// 1、传入bootstrap-server参数
	public static String bootStrapServer = "cluster1.hadoop:6667,clusterkk::6667";
	public static String topic = "RealTimeMessage4Job014";
	static {

		// 2、构建KafkaProducerUtil4Java对象
		producerUtil = new KafkaProducerUtil4Java(bootStrapServer);
	}

	// 写一个静态方法，实现简易、高效的数据发送至kafka cluster功能
	public static void sendData(String message) {
		producerUtil.producer.send(new ProducerRecord<String, String>(topic,
				message));
	}
}
